// 导入express模块
var express = require('express');
var path = require('path');
var fs = require('fs');
// 导入路由模块
var router = express.Router();
// 导入url模块
var url = require('url');
// 导入mysql模块 
var mysql = require('mysql');
// 导入数据库配置信息
var dbconfig = require('../db/DBConfig');
// 导入SQL查询语句
var bclass = require('../sql/Bclasssql.js');
// 导入自定义公共类
var util = require('../utils/util');
// 使用DBConfig.js的配置信息创建一个MySQL连接池
var pool = mysql.createPool(dbconfig.mysql);

var savapatha = dbconfig.savepath.path;
//上传文件接口

router.post('/add', function(req, res, next) {
    
    if (req.busboy) {
        req.busboy.on('file', function (fieldname, file, filename, encoding, mimetype) {
            var nfname =util.randomString(3)+filename ;
            var saveTo = path.join(savapatha,nfname);       
            file.pipe(fs.createWriteStream(saveTo));
            file.on('end', function () {
                //在这边可以做一些数据库操作
                res.json({
                    success: true,
                    data:nfname
                });
            });
        });
        req.pipe(req.busboy);
    }
});


module.exports = router;